//package org.znxs.znxsframe.mq_test;
//
//import com.rabbitmq.client.Channel;
//import com.rabbitmq.client.Connection;
//import com.rabbitmq.client.ConnectionFactory;
//
//import java.nio.charset.StandardCharsets;
//
//public class SingleProvider {
//
//    private final static String QUEUE_NAME = "hello";
//
//    public static void main(String[] argv) throws Exception {
//        // 连接工厂
//        ConnectionFactory factory = new ConnectionFactory();
//        factory.setHost("localhost");
//        // 创建链接
//        try (Connection connection = factory.newConnection();
//             Channel channel = connection.createChannel()) {
//            // 声明消息队列
//            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
//            String message = "Hello World!";
//            // 发布消息
//            for (int i = 0; i < 4; i++) {
//                channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));
//            }
//
//            System.out.println(" [x] Sent '" + message + "'");
//        }
//    }
//}